package com.hong.concurrent.chapter12;

import java.io.IOException;

/**
 * @Author csh
 * @Description 监督者
 *
 * 此方法的作用为防止生产者在生产的时候由于return的时候阻塞住了，此方法进行save操作。起到一个监督的作用
 *
 * @Date 2018/7/8 11:09
 */
public class WaiterThread extends  Thread{
    private final BalkingData balkingData;

    public WaiterThread(BalkingData balkingData) {
        super("Waiter");
        this.balkingData = balkingData;
    }


    @Override
    public void run() {
        for (int i = 0;i<200;i++){
            try {
                balkingData.save();
                Thread.sleep(1_000L);
            } catch (IOException e) {
                e.printStackTrace();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}
